package com.tenton.netty.multicast;

import io.netty.channel.ChannelInitializer;
import io.netty.channel.ChannelPipeline;
import io.netty.channel.socket.nio.NioDatagramChannel;

/**
 * @ClassName: DataRecvInitializer
 * @Description:  UDP配置
 * @Author： tangdong
 * @Date： 2024/6/25
 */
public class DataRecvInitializer extends ChannelInitializer<NioDatagramChannel> {
    @Override
    protected void initChannel(NioDatagramChannel nch) throws Exception {
        ChannelPipeline pipeline = nch.pipeline();
        pipeline.addLast(new DataRecvHandler());
    }
}
